//package com.code.manager;
//
//import com.alibaba.fastjson.JSON;
//import com.google.common.collect.Maps;
//import lombok.extern.slf4j.Slf4j;
//import org.java_websocket.WebSocket;
//import org.java_websocket.client.WebSocketClient;
//import org.java_websocket.drafts.Draft;
//import org.java_websocket.drafts.Draft_6455;
//import org.java_websocket.handshake.ServerHandshake;
//import org.springframework.beans.factory.annotation.Value;
//
//import java.net.URI;
//import java.net.URISyntaxException;
//import java.util.Map;
//
//@Slf4j
//public class WebSocketManager extends WebSocketClient {
//
//    @Value("${XT.single.twentyFourHoursMarket.socketUrl}")
//    private String socketUrl;
//
//    public WebSocketManager(URI serverUri, Draft protocolDraft) {
//        super(serverUri, protocolDraft);
//    }
//
//    @Override
//    public void onOpen(ServerHandshake arg0) {
//        System.out.println("开始建立链接...");
//    }
//
//
//    @Override
//    public void onMessage(String message) {
//        System.out.println("检测到服务器请求...message： " + message);
//    }
//
//
//    @Override
//    public void onError(Exception arg0) {
//        arg0.printStackTrace();
//        System.out.println("客户端发生错误,即将关闭!");
//    }
//
//
//    @Override
//    public void onClose(int arg0, String arg1, boolean arg2) {
//        System.out.println("客户端已关闭!");
//    }
//
//
//    public static void main(String[] args) throws URISyntaxException, InterruptedException {
//        WebSocketManager client = new WebSocketManager(new URI("wss://ws.xt.com/websocket"), new Draft_6455());
//        boolean f = client.connectBlocking();
//        System.out.println("connectBlocking: " + f);
//        //判断连接状态,
//        if (client.getReadyState().equals(WebSocket.READYSTATE.OPEN)) {
//            System.out.println("成功链接!");
//            // 往websocket服务端发送数据
//            Map<String, Object> map = Maps.newHashMapWithExpectedSize(1 << 3);
//            map.put("dataType", "ALL_TRADE_STATISTIC_24H");
//            map.put("dataSize", 1);
//            map.put("action", "ADD");
//            client.send(JSON.toJSONString(map));
//        }
//    }
//}